package day3

import Utils.SparkUtils

object Test2_aggregateByKey {
  def main(args: Array[String]): Unit = {
    // 再看一遍昨天倒数第二个视频 join
    val sc = SparkUtils.getSparkContext(4,"yy")
    val rdd1 = sc.makeRDD(List(("a",3),("a",2),("c",4),("b",3),("c",6),("c",8)),2)
    val rdd2 = rdd1.aggregateByKey(0)((v1,v2) => if (v1>v2) v1 else v2,(v1,v2) => v1+v2)
    rdd2.collect().foreach(v => println(v))
    sc.stop()
  }
}
